package com.wux.labs.integration.kafka.processor;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(ConsumerProcessor.class)
public class ConsumerProcessorImpl {
    @StreamListener("kafkaChannel2")
    public void kafkaStreamListener(Object message) {
        System.out.println("接收到Kafka消息：" + new String((byte[]) message));
    }
}
